//package com.lh.center.common.web.mq.consumer;
//
//import org.apache.rocketmq.client.apis.ClientConfiguration;
//import org.apache.rocketmq.client.apis.ClientServiceProvider;
//import org.springframework.beans.factory.annotation.Value;
//
//public abstract class AbstractMarketingConsumer {
//
//
//    public ClientServiceProvider provider = ClientServiceProvider.loadService();
//
//
//    @Value("${mq.endpoint:}")
//    public String endpoint;
//
//
//
//
//
//    public ClientConfiguration getClientConfiguration() {
//        ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
//                .setEndpoints(endpoint)
//                .build();
//        return clientConfiguration;
//    }
//
//
//}
